ff0196f69a7b8e272592bfec7661dffe2a1a5ea7,hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSink.java,TestReplicationSink,testMixedDeletes,#,180

Before Change



    entries[0] = createEntry(TABLE_NAME1, 0, KeyValue.Type.DeleteColumn);
    entries[1] = createEntry(TABLE_NAME1, 1, KeyValue.Type.DeleteFamily);
    entries[2] = createEntry(TABLE_NAME1, 2, KeyValue.Type.DeleteColumn);

    SINK.replicateEntries(entries);

After Change


      entries.add(createEntry(TABLE_NAME1, i, KeyValue.Type.Put, cells));
    }
    SINK.replicateEntries(entries, CellUtil.createCellScanner(cells.iterator()));
    entries = new ArrayList<WALEntry>(3);
    cells = new ArrayList<Cell>();
    entries.add(createEntry(TABLE_NAME1, 0, KeyValue.Type.DeleteColumn, cells));
    entries.add(createEntry(TABLE_NAME1, 1, KeyValue.Type.DeleteFamily, cells));
    entries.add(createEntry(TABLE_NAME1, 2, KeyValue.Type.DeleteColumn, cells));

    SINK.replicateEntries(entries, CellUtil.createCellScanner(cells.iterator()));

    Scan scan = new Scan();
    ResultScanner scanRes = table1.getScanner(scan);